package cn.lgwen.candy.runtime.operator;

/**
 * 2019/12/24
 * aven.wu
 * danxieai258@163.com
 * I 表示输入类型 O表示输出类型
 */
public abstract class Processor<I, O> extends AbstractOperator {

    /**
     * process element
     * @param input
     * @param out
     */
    public abstract void process(I input, Collector<O> out);

}
